const { Pool } = require('pg')

// 创建连接池对象
const pool = new Pool({
  user: 'postgres', // 用户名
  password: 'postgres', // 密码
  host: 'localhost', // 主机
  port: 5432, // 端口
  database: 'express_file_system'
})

// sql 查询
function query(query, callback, res) {
  pool.connect((err, connection) => {
    if (err) {
      console.log('connect error: ', err)
      res && res.status(500).send(err)
    } else {
      connection.query(query, (err, result) => {
        callback && callback(err, result)
        // 释放连接对象
        connection.release()
      })
    }
  })
}

exports.query = query
